#define _GNU_SOURCE // 如是不声明gettid()不识别报错
#include <unistd.h>
#include "app_mqtt.h"
#include "log/log.h"
#include <unistd.h>

int recv_callback(char *data, int len)
{
    log_warn("处理接收的消息(tid=%d)，消息内容：%s，消息长度：%d", gettid(), data, len);
    return 0; // 一定要返回0
}

int main(int argc, char const *argv[])
{
    log_debug("main线程执行(tid=%d)", gettid());
    app_mqtt_init();

    app_mqtt_registRecvCallback(recv_callback);

    app_mqtt_send("abcdef", 6);

    sleep(30);
    log_debug("程序结束");

    return 0;
}
